package com.yly.stream;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
//@EnableBinding(Sink.class) 同理 不直接用 不写在启动类
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class);
    }
//	@StreamListener(Sink.INPUT)
//	public void input(String message){
//		System.out.println("获取的消息+"+message);
//
//	}
}